import redis
import datetime
import time

if '__main__' == __name__:

    # 连接本机6379端口上的redis的第0个数据库
    rdb = redis.Redis('127.0.0.1', 6379, 0)

    xuuid = str(datetime.datetime.now())
    print('uuid:', xuuid)

    r = rdb.hset('uuid2input', xuuid, '输入字符串001'.encode('utf8'))
    print(r)
    r = rdb.hset('uuid2username', xuuid, '用户名001'.encode('utf8'))
    print(r)
    r = rdb.lpush('queue001', xuuid)
    print(r)

    # 拿输出
    print('Waiting data ...')
    while True:
        xoutput = rdb.hget('uuid2output', xuuid)
        if xoutput is None:
            time.sleep(0.001)
            continue
        else:
            break

    xoutput = xoutput.decode('utf8')
    print('output:', xoutput)

    print('over')
